package com.rocketmq.consumer.config;

import lombok.Data;
import lombok.ToString;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * Mq配置信息
 */
@Data
@ToString
@Component
public class MqConfig {

    @Value("${namesrvAddr}")
    private String namesrvAddr;
    @Value("${consumeMessageBatchMaxSize}")
    private int consumeMessageBatchMaxSize;
    @Value("${heartbeatBrokerInterval}")
    private int heartbeatBrokerInterval;
    @Value("${pullInterval}")
    private long pullInterval;
    @Value("${pullThresholdForQueue}")
    private int pullThresholdForQueue;
    @Value("${persistConsumerOffsetInterval}")
    private int persistConsumerOffsetInterval;
}
